+++ /dev/null
-#include <uv.h>
-#include <stdio.h>
-#include <stdlib.h>
-
-void OnConnect(uv_connect_t * connect, int status)
-{
- printf("Hi!");
-}
-
-int main()
-{
- uv_loop_t * loop = uv_default_loop();
- uv_pipe_t * handle = malloc(sizeof(uv_pipe_t));
- uv_connect_t * connect = malloc(sizeof(uv_connect_t));
-
- uv_pipe_init(loop, handle, 0);
- uv_pipe_open(handle, socket(PF_UNIX, SOCK_STREAM, 0));
- uv_pipe_connect(connect, handle, "/tmp/siridb_pipe_test.sock", OnConnect);
-
- uv_run(loop, UV_RUN_DEFAULT);
-}
\ No newline at end of file
[1538660010, 35.6],
[1538660020, "-50,6%"],
[1538660030, ""],
+ [1538660035, "garbage"],
+ [1538660040, "18446744073709551616"],
+ [1538660050, "-18446744073709551616"],
],
'double': [
[1538660000, 1.0],
[1538660010, -35],
[1538660010, "-50,6%"],
[1538660030, ""],
+ [1538660035, "garbage"],
]
}
[1538660010, 35],
[1538660020, -50],
[1538660030, 0],
+ [1538660035, 0],
+ [1538660040, 9223372036854775807],
+ [1538660050, -9223372036854775808],
],
'double': [
[1538660000, 1.0],
[1538660010, -35.0],
[1538660010, -50.6],
[1538660030, 0.0],
+ [1538660035, 0],
]
}
self.assertEqual(
await self.client0.insert(data),
- {'success_msg': 'Successfully inserted 12 point(s).'})
+ {'success_msg': 'Successfully inserted 16 point(s).'})
self.assertAlmostEqual(
await self.client0.query(
"Successfully granted permissions to user 'sasientje'.")
await self.db.add_replica(self.server1, 0)
- await self.assertIsRunning(self.db, self.client0, timeout=10)
+ await self.assertIsRunning(self.db, self.client0, timeout=20)
await self.db.add_pool(self.server2)
await self.client1.connect()
await self.client2.connect()
+ await asyncio.sleep(15)
+
result = await self.client1.query('list users where access < full ')
self.assertEqual(result.pop('users'), [['sasientje', 'modify']])